from multiprocessing import Process
from multiprocessing import Queue
import os, time
a = 100
# 入队
# 参数q 为队列
def write_msg(q):
    global a
    if not q.full():
        for i in range(6):
            a -= 10
            q.put(a)
            print("入队的值：", a)
# 出队
def read_msg(q):
    time.sleep(1)
    while not q.empty():
        print("出队的值：", q.get())
if __name__ == '__main__':
    # 主进程
    print("主进程开始执行")
    # 创建一个队列,不写参数的话指队列没有上限
    q = Queue()
    # 创建两个子进程
    p1 = Process(target=write_msg, args=(q,))
    p2 = Process(target=read_msg, args=(q,))
    # 启动两个子进程
    p1.start()
    p2.start()
    # 阻塞进程
    p1.join()
    p2.join()
    print("主进程执行结束")
